package com.ydl.learning.flink.demo.pipeline

import org.apache.flink.streaming.api.scala.DataStream

/**
 *
 *
 * @author ydl
 * @since 2022/1/7
 */
trait Process[T] extends BaseProcedure {
  protected var dataStream: DataStream[T] = _

  def setData(dataStream: DataStream[T]): Unit = {
    this.dataStream = dataStream
  }

  def run: DataStream[T]
}
